package com.liuzhilong.infrastructure.framework.ioreactor;

import reactor.core.publisher.Flux;

public class UseCase {
    public static void main(String[] args) {
//        Flux<String> flux = Flux.create(emitter -> {
//            for (int i = 0; i < 10; i++) {
//                emitter.next("" + i);
//            }
//            emitter.complete();
//        }).map(Object::toString).map(String::toUpperCase).subscribe(System.out::println);
    }
}
